e46f4131f9eade2eb9fe108241107688795904f5,nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java,Wait,onTrigger,#ProcessContext#ProcessSession#,197

Before Change


                if (logger.isDebugEnabled()) {
                    logger.debug("No release signal yet for {} on FlowFile {}", new Object[] {signalId, flowFile});
                }
                session.transfer(flowFile, REL_WAIT);
                return;
            }

After Change



                final String waitMode = context.getProperty(WAIT_MODE).getValue();
                if (WAIT_MODE_TRANSFER_TO_WAIT.getValue().equals(waitMode)) {
                    session.transfer(flowFile, REL_WAIT);
                } else if (WAIT_MODE_KEEP_IN_UPSTREAM.getValue().equals(waitMode)) {
                    // Transfer to self.
                    session.transfer(flowFile);